Node / meshtastic / Meshtastic-Android / files / feature / discovery / src / commonTest / kotlin / org / meshtastic / feature / discovery / DiscoveryPacketCollectionTest.kt

Displaying Raw • Download

T8b949e/*

* Copyright (c) 2026 Meshtastic LLC

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tf0883e@fileTb4b4b4:Te6edf3SuppressTb4b4b4(Ta5d6ff"Ta5d6ffMagicNumberTa5d6ff"Tb4b4b4)

Tff7b72package T7ee787org.meshtastic.feature.discovery

Tff7b72import T7ee787kotlinx.coroutines.SupervisorJob

Tff7b72import T7ee787kotlinx.coroutines.delay

Tff7b72import T7ee787kotlinx.coroutines.flow.Flow

Tff7b72import T7ee787kotlinx.coroutines.flow.MutableStateFlow

Tff7b72import T7ee787kotlinx.coroutines.flow.flowOf

Tff7b72import T7ee787kotlinx.coroutines.test.TestScope

Tff7b72import T7ee787kotlinx.coroutines.test.UnconfinedTestDispatcher

Tff7b72import T7ee787kotlinx.coroutines.test.runTest

Tff7b72import T7ee787okio.ByteString

Tff7b72import T7ee787okio.ByteString.Companion.toByteString

Tff7b72import T7ee787org.meshtastic.core.common.di.ApplicationCoroutineScope

Tff7b72import T7ee787org.meshtastic.core.database.dao.DiscoveryDao

Tff7b72import T7ee787org.meshtastic.core.database.entity.DiscoveredNodeEntity

Tff7b72import T7ee787org.meshtastic.core.database.entity.DiscoveryPresetResultEntity

Tff7b72import T7ee787org.meshtastic.core.database.entity.DiscoverySessionEntity

Tff7b72import T7ee787org.meshtastic.core.di.CoroutineDispatchers

Tff7b72import T7ee787org.meshtastic.core.model.ChannelOption

Tff7b72import T7ee787org.meshtastic.core.model.ConnectionState

Tff7b72import T7ee787org.meshtastic.core.model.DataPacket

Tff7b72import T7ee787org.meshtastic.core.model.MyNodeInfo

Tff7b72import T7ee787org.meshtastic.core.model.NodeAddress

Tff7b72import T7ee787org.meshtastic.core.repository.DiscoveryPacketCollector

Tff7b72import T7ee787org.meshtastic.core.repository.DiscoveryPacketCollectorRegistry

Tff7b72import T7ee787org.meshtastic.core.testing.FakeMeshPrefs

Tff7b72import T7ee787org.meshtastic.core.testing.FakeNodeRepository

Tff7b72import T7ee787org.meshtastic.core.testing.FakeRadioConfigRepository

Tff7b72import T7ee787org.meshtastic.core.testing.FakeRadioController

Tff7b72import T7ee787org.meshtastic.core.testing.FakeServiceRepository

Tff7b72import T7ee787org.meshtastic.feature.discovery.ai.DiscoverySummaryAiProvider

Tff7b72import T7ee787org.meshtastic.proto.Config

Tff7b72import T7ee787org.meshtastic.proto.Data

Tff7b72import T7ee787org.meshtastic.proto.LocalConfig

Tff7b72import T7ee787org.meshtastic.proto.MeshPacket

Tff7b72import T7ee787org.meshtastic.proto.Neighbor

Tff7b72import T7ee787org.meshtastic.proto.NeighborInfo

Tff7b72import T7ee787org.meshtastic.proto.PortNum

Tff7b72import T7ee787org.meshtastic.proto.Position

Tff7b72import T7ee787kotlin.test.Test

Tff7b72import T7ee787kotlin.test.assertEquals

Tff7b72import T7ee787kotlin.test.assertNull

Tff7b72import T7ee787kotlin.test.assertTrue

T8b949e/**

* Tests for edge cases in packet collection: duplicate packets, nodes without positions, and neighbor-info-only

* sightings (D023).

*/

Tff7b72class T56d364DiscoveryPacketCollectionTest Tb4b4b4{

Tff7b72private Tff7b72val Te6edf3radioController Tff7b72= Te6edf3FakeRadioControllerTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3serviceRepository Tff7b72= Te6edf3FakeServiceRepositoryTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3apply Tb4b4b4{ Te6edf3setConnectionStateTb4b4b4(Te6edf3ConnectionStateTb4b4b4.Te6edf3ConnectedTb4b4b4) Tb4b4b4}

Tff7b72private Tff7b72val Te6edf3nodeRepository Tff7b72= Te6edf3FakeNodeRepositoryTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3radioConfigRepository Tff7b72=

Te6edf3FakeRadioConfigRepositoryTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3apply Tb4b4b4{

Te6edf3setLocalConfigDirectTb4b4b4(

Te6edf3LocalConfigTb4b4b4(

Te6edf3lora Tff7b72= Te6edf3ConfigTb4b4b4.Te6edf3LoRaConfigTb4b4b4(Te6edf3use_preset Tff7b72= Tff7b72trueTb4b4b4, Te6edf3modem_preset Tff7b72= Te6edf3ChannelOptionTb4b4b4.Te6edf3LONG_FASTTb4b4b4.Te6edf3modemPresetTb4b4b4)Tb4b4b4,

Tb4b4b4)Tb4b4b4,

Tb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72val Te6edf3collectorRegistry Tff7b72= Te6edf3PacketTestCollectorRegistryTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3discoveryDao Tff7b72= Te6edf3InMemoryDiscoveryDaoTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3aiProvider Tff7b72= Te6edf3PacketTestAiProviderTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3meshPrefs Tff7b72= Te6edf3FakeMeshPrefsTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72fun Td2a8ffcreateEngineTb4b4b4(Te6edf3testScopeTb4b4b4: Te6edf3TestScopeTb4b4b4)Tb4b4b4: Te6edf3DiscoveryScanEngine Tb4b4b4{

Tff7b72val Te6edf3testDispatcher Tff7b72= Te6edf3UnconfinedTestDispatcherTb4b4b4(Te6edf3testScopeTb4b4b4.Te6edf3testSchedulerTb4b4b4)

Tff7b72val Te6edf3dispatchers Tff7b72= Te6edf3CoroutineDispatchersTb4b4b4(Te6edf3io Tff7b72= Te6edf3testDispatcherTb4b4b4, Te6edf3main Tff7b72= Te6edf3testDispatcherTb4b4b4, Te6edf3default Tff7b72= Te6edf3testDispatcherTb4b4b4)

Tff7b72val Te6edf3appScope Tff7b72=

Tff7b72object Tb4b4b4: T56d364ApplicationCoroutineScope Tb4b4b4{

Tff7b72override Tff7b72val Te6edf3coroutineContext Tff7b72= Te6edf3testDispatcher Tff7b72+ Te6edf3SupervisorJobTb4b4b4(Tb4b4b4)

Tb4b4b4}

Tff7b72return Te6edf3DiscoveryScanEngineTb4b4b4(

Te6edf3radioController Tff7b72= Te6edf3radioControllerTb4b4b4,

Te6edf3serviceRepository Tff7b72= Te6edf3serviceRepositoryTb4b4b4,

Te6edf3nodeRepository Tff7b72= Te6edf3nodeRepositoryTb4b4b4,

Te6edf3radioConfigRepository Tff7b72= Te6edf3radioConfigRepositoryTb4b4b4,

Te6edf3collectorRegistry Tff7b72= Te6edf3collectorRegistryTb4b4b4,

Te6edf3discoveryDao Tff7b72= Te6edf3discoveryDaoTb4b4b4,

Te6edf3aiProvider Tff7b72= Te6edf3aiProviderTb4b4b4,

Te6edf3applicationScope Tff7b72= Te6edf3appScopeTb4b4b4,

Te6edf3dispatchers Tff7b72= Te6edf3dispatchersTb4b4b4,

Te6edf3meshPrefs Tff7b72= Te6edf3meshPrefsTb4b4b4,

Tb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72val Te6edf3testPresets Tff7b72= Te6edf3listOfTb4b4b4(Te6edf3ChannelOptionTb4b4b4.Te6edf3LONG_FASTTb4b4b4)

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffawaitDwellTb4b4b4(Te6edf3engineTb4b4b4: Te6edf3DiscoveryScanEngineTb4b4b4) Tb4b4b4{

Tff7b72while Tb4b4b4(Te6edf3engineTb4b4b4.Te6edf3scanStateTb4b4b4.Te6edf3value Tff7b72!is Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3DwellTb4b4b4) Tb4b4b4{

Te6edf3delayTb4b4b4(T79c0ff5T79c0ff0Tb4b4b4)

Tb4b4b4}

Tb4b4b4}

T8b949e// region Duplicate packets

Tf0883e@Test

Tff7b72fun Td2a8ffduplicatePacketsFromSameNodeDeduplicateByNodeNumTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3engine Tff7b72= Te6edf3createEngineTb4b4b4(Tff7b72thisTb4b4b4)

Te6edf3nodeRepositoryTb4b4b4.Te6edf3setMyNodeInfoTb4b4b4(Te6edf3createMyNodeInfoTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3startScanTb4b4b4(Te6edf3testPresetsTb4b4b4, Te6edf3dwellDurationSeconds Tff7b72= T79c0ff6T79c0ff0Tb4b4b4)

Te6edf3awaitDwellTb4b4b4(Te6edf3engineTb4b4b4)

T8b949e// Send two position packets from the same node

Tff7b72val Te6edf3meshPacket1 Tff7b72= Te6edf3positionPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff1T79c0ff1T79c0ff1T79c0ff1Tb4b4b4, Te6edf3latI Tff7b72= T79c0ff3T79c0ff7T79c0ff7T79c0ff7T79c0ff4T79c0ff9T79c0ff0T79c0ff0T79c0ff0Tb4b4b4, Te6edf3lonI Tff7b72= Tff7b72-T79c0ff1T79c0ff2T79c0ff2T79c0ff4T79c0ff1T79c0ff9T79c0ff4T79c0ff0T79c0ff0T79c0ff0Tb4b4b4, Te6edf3snr Tff7b72= T79c0ff5.0fTb4b4b4, Te6edf3rssi Tff7b72= Tff7b72-T79c0ff7T79c0ff0Tb4b4b4)

Tff7b72val Te6edf3meshPacket2 Tff7b72= Te6edf3positionPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff1T79c0ff1T79c0ff1T79c0ff1Tb4b4b4, Te6edf3latI Tff7b72= T79c0ff3T79c0ff7T79c0ff7T79c0ff7T79c0ff5T79c0ff0T79c0ff0T79c0ff0T79c0ff0Tb4b4b4, Te6edf3lonI Tff7b72= Tff7b72-T79c0ff1T79c0ff2T79c0ff2T79c0ff4T79c0ff1T79c0ff9T79c0ff5T79c0ff0T79c0ff0T79c0ff0Tb4b4b4, Te6edf3snr Tff7b72= T79c0ff8.0fTb4b4b4, Te6edf3rssi Tff7b72= Tff7b72-T79c0ff5T79c0ff5Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3onPacketReceivedTb4b4b4(Te6edf3meshPacket1Tb4b4b4, Te6edf3dataPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff1T79c0ff1T79c0ff1T79c0ff1Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3onPacketReceivedTb4b4b4(Te6edf3meshPacket2Tb4b4b4, Te6edf3dataPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff1T79c0ff1T79c0ff1T79c0ff1Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3stopScanTb4b4b4(Tb4b4b4)

T8b949e// Only one discovered node for nodeNum=1111

Tff7b72val Te6edf3nodes Tff7b72= Te6edf3discoveryDaoTb4b4b4.Te6edf3discoveredNodesTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3nodesTb4b4b4.Te6edf3sizeTb4b4b4, Ta5d6ff"Ta5d6ffDuplicate packets should map to a single node entryTa5d6ff"Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff1T79c0ff1T79c0ff1T79c0ff1LTb4b4b4, Te6edf3nodesTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3nodeNumTb4b4b4)

T8b949e// Second packet's SNR/RSSI should overwrite first

Te6edf3assertEqualsTb4b4b4(T79c0ff8.0fTb4b4b4, Te6edf3nodesTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3snrTb4b4b4, Ta5d6ff"Ta5d6ffLater SNR should overwriteTa5d6ff"Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(Tff7b72-T79c0ff5T79c0ff5Tb4b4b4, Te6edf3nodesTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3rssiTb4b4b4, Ta5d6ff"Ta5d6ffLater RSSI should overwriteTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ffduplicatePacketsCountMessagesAccumulativelyTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3engine Tff7b72= Te6edf3createEngineTb4b4b4(Tff7b72thisTb4b4b4)

Te6edf3nodeRepositoryTb4b4b4.Te6edf3setMyNodeInfoTb4b4b4(Te6edf3createMyNodeInfoTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3startScanTb4b4b4(Te6edf3testPresetsTb4b4b4, Te6edf3dwellDurationSeconds Tff7b72= T79c0ff6T79c0ff0Tb4b4b4)

Te6edf3awaitDwellTb4b4b4(Te6edf3engineTb4b4b4)

T8b949e// Send 3 text messages from same node

Te6edf3repeatTb4b4b4(T79c0ff3Tb4b4b4) Tb4b4b4{ Te6edf3engineTb4b4b4.Te6edf3onPacketReceivedTb4b4b4(Te6edf3textMessagePacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff2T79c0ff2T79c0ff2T79c0ff2Tb4b4b4)Tb4b4b4, Te6edf3dataPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff2T79c0ff2T79c0ff2T79c0ff2Tb4b4b4)Tb4b4b4) Tb4b4b4}

Te6edf3engineTb4b4b4.Te6edf3stopScanTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3nodes Tff7b72= Te6edf3discoveryDaoTb4b4b4.Te6edf3discoveredNodesTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3nodesTb4b4b4.Te6edf3sizeTb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff3Tb4b4b4, Te6edf3nodesTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3messageCountTb4b4b4, Ta5d6ff"Ta5d6ffMessage count should accumulate across duplicate packetsTa5d6ff"Tb4b4b4)

Tb4b4b4}

T8b949e// endregion

T8b949e// region Nodes without positions

Tf0883e@Test

Tff7b72fun Td2a8ffnodeWithoutPositionHasNullLatLonTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3engine Tff7b72= Te6edf3createEngineTb4b4b4(Tff7b72thisTb4b4b4)

Te6edf3nodeRepositoryTb4b4b4.Te6edf3setMyNodeInfoTb4b4b4(Te6edf3createMyNodeInfoTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3startScanTb4b4b4(Te6edf3testPresetsTb4b4b4, Te6edf3dwellDurationSeconds Tff7b72= T79c0ff6T79c0ff0Tb4b4b4)

Te6edf3awaitDwellTb4b4b4(Te6edf3engineTb4b4b4)

T8b949e// Send a text message with no position data

Te6edf3engineTb4b4b4.Te6edf3onPacketReceivedTb4b4b4(Te6edf3textMessagePacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff3T79c0ff3T79c0ff3T79c0ff3Tb4b4b4)Tb4b4b4, Te6edf3dataPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff3T79c0ff3T79c0ff3T79c0ff3Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3stopScanTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3nodes Tff7b72= Te6edf3discoveryDaoTb4b4b4.Te6edf3discoveredNodesTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3nodesTb4b4b4.Te6edf3sizeTb4b4b4)

Te6edf3assertNullTb4b4b4(Te6edf3nodesTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3latitudeTb4b4b4, Ta5d6ff"Ta5d6ffNode without position should have null latitudeTa5d6ff"Tb4b4b4)

Te6edf3assertNullTb4b4b4(Te6edf3nodesTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3longitudeTb4b4b4, Ta5d6ff"Ta5d6ffNode without position should have null longitudeTa5d6ff"Tb4b4b4)

Te6edf3assertNullTb4b4b4(Te6edf3nodesTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3distanceFromUserTb4b4b4, Ta5d6ff"Ta5d6ffNode without position should have null distanceTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ffnodeWithZeroPositionTreatedAsNoPositionTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3engine Tff7b72= Te6edf3createEngineTb4b4b4(Tff7b72thisTb4b4b4)

Te6edf3nodeRepositoryTb4b4b4.Te6edf3setMyNodeInfoTb4b4b4(Te6edf3createMyNodeInfoTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3startScanTb4b4b4(Te6edf3testPresetsTb4b4b4, Te6edf3dwellDurationSeconds Tff7b72= T79c0ff6T79c0ff0Tb4b4b4)

Te6edf3awaitDwellTb4b4b4(Te6edf3engineTb4b4b4)

T8b949e// Position of 0,0 is treated as invalid/no fix

Tff7b72val Te6edf3packet Tff7b72= Te6edf3positionPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff4T79c0ff4T79c0ff4T79c0ff4Tb4b4b4, Te6edf3latI Tff7b72= T79c0ff0Tb4b4b4, Te6edf3lonI Tff7b72= T79c0ff0Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3onPacketReceivedTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3dataPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff4T79c0ff4T79c0ff4T79c0ff4Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3stopScanTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3nodes Tff7b72= Te6edf3discoveryDaoTb4b4b4.Te6edf3discoveredNodesTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3nodesTb4b4b4.Te6edf3sizeTb4b4b4)

Te6edf3assertNullTb4b4b4(Te6edf3nodesTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3distanceFromUserTb4b4b4, Ta5d6ff"Ta5d6ffZero-position node should have null distanceTa5d6ff"Tb4b4b4)

Tb4b4b4}

T8b949e// endregion

T8b949e// region Neighbor-info-only sightings

Tf0883e@Test

Tff7b72fun Td2a8ffneighborInfoOnlyNodeIsMarkedAsMeshTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3engine Tff7b72= Te6edf3createEngineTb4b4b4(Tff7b72thisTb4b4b4)

Te6edf3nodeRepositoryTb4b4b4.Te6edf3setMyNodeInfoTb4b4b4(Te6edf3createMyNodeInfoTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3startScanTb4b4b4(Te6edf3testPresetsTb4b4b4, Te6edf3dwellDurationSeconds Tff7b72= T79c0ff6T79c0ff0Tb4b4b4)

Te6edf3awaitDwellTb4b4b4(Te6edf3engineTb4b4b4)

T8b949e// Send a neighbor info packet that references node 5555 as a mesh neighbor

Tff7b72val Te6edf3niPacket Tff7b72= Te6edf3neighborInfoPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff9T79c0ff9T79c0ff9T79c0ff9Tb4b4b4, Te6edf3neighborNodeIds Tff7b72= Te6edf3listOfTb4b4b4(T79c0ff5T79c0ff5T79c0ff5T79c0ff5Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3onPacketReceivedTb4b4b4(Te6edf3niPacketTb4b4b4, Te6edf3dataPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff9T79c0ff9T79c0ff9T79c0ff9Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3stopScanTb4b4b4(Tb4b4b4)

T8b949e// Node 5555 should appear as a mesh neighbor even though we never received a direct packet from it

Tff7b72val Te6edf3nodes Tff7b72= Te6edf3discoveryDaoTb4b4b4.Te6edf3discoveredNodesTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3meshNode Tff7b72= Te6edf3nodesTb4b4b4.Te6edf3find Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3nodeNum Tff7b72=Tff7b72= T79c0ff5T79c0ff5T79c0ff5T79c0ff5L Tb4b4b4}

Te6edf3assertTrueTb4b4b4(Te6edf3meshNode Tff7b72!Tff7b72= Tff7b72nullTb4b4b4, Ta5d6ff"Ta5d6ffNeighbor-info-only node should be persistedTa5d6ff"Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ffmeshTa5d6ff"Tb4b4b4, Te6edf3meshNodeTb4b4b4.Te6edf3neighborTypeTb4b4b4, Ta5d6ff"Ta5d6ffNeighbor-info-only node should have 'mesh' typeTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ffneighborInfoDoesNotOverrideDirectTypeTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3engine Tff7b72= Te6edf3createEngineTb4b4b4(Tff7b72thisTb4b4b4)

Te6edf3nodeRepositoryTb4b4b4.Te6edf3setMyNodeInfoTb4b4b4(Te6edf3createMyNodeInfoTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3startScanTb4b4b4(Te6edf3testPresetsTb4b4b4, Te6edf3dwellDurationSeconds Tff7b72= T79c0ff6T79c0ff0Tb4b4b4)

Te6edf3awaitDwellTb4b4b4(Te6edf3engineTb4b4b4)

T8b949e// First: receive a direct packet from node 6666

Te6edf3engineTb4b4b4.Te6edf3onPacketReceivedTb4b4b4(

Te6edf3positionPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff6T79c0ff6T79c0ff6T79c0ff6Tb4b4b4, Te6edf3latI Tff7b72= T79c0ff3T79c0ff7T79c0ff7T79c0ff7T79c0ff4T79c0ff9T79c0ff0T79c0ff0T79c0ff0Tb4b4b4, Te6edf3lonI Tff7b72= Tff7b72-T79c0ff1T79c0ff2T79c0ff2T79c0ff4T79c0ff1T79c0ff9T79c0ff4T79c0ff0T79c0ff0T79c0ff0Tb4b4b4, Te6edf3snr Tff7b72= T79c0ff1T79c0ff0fTb4b4b4, Te6edf3rssi Tff7b72= Tff7b72-T79c0ff4T79c0ff0Tb4b4b4)Tb4b4b4,

Te6edf3dataPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff6T79c0ff6T79c0ff6T79c0ff6Tb4b4b4)Tb4b4b4,

Tb4b4b4)

T8b949e// Then: receive neighbor info that also references 6666

Tff7b72val Te6edf3niPacket Tff7b72= Te6edf3neighborInfoPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff8T79c0ff8T79c0ff8T79c0ff8Tb4b4b4, Te6edf3neighborNodeIds Tff7b72= Te6edf3listOfTb4b4b4(T79c0ff6T79c0ff6T79c0ff6T79c0ff6Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3onPacketReceivedTb4b4b4(Te6edf3niPacketTb4b4b4, Te6edf3dataPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff8T79c0ff8T79c0ff8T79c0ff8Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3stopScanTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3nodes Tff7b72= Te6edf3discoveryDaoTb4b4b4.Te6edf3discoveredNodesTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3directNode Tff7b72= Te6edf3nodesTb4b4b4.Te6edf3find Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3nodeNum Tff7b72=Tff7b72= T79c0ff6T79c0ff6T79c0ff6T79c0ff6L Tb4b4b4}

Te6edf3assertTrueTb4b4b4(Te6edf3directNode Tff7b72!Tff7b72= Tff7b72nullTb4b4b4, Ta5d6ff"Ta5d6ffNode should be persistedTa5d6ff"Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ffdirectTa5d6ff"Tb4b4b4, Te6edf3directNodeTb4b4b4.Te6edf3neighborTypeTb4b4b4, Ta5d6ff"Ta5d6ffDirect type should not be overridden by neighbor-infoTa5d6ff"Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff1T79c0ff0fTb4b4b4, Te6edf3directNodeTb4b4b4.Te6edf3snrTb4b4b4, Ta5d6ff"Ta5d6ffSNR from direct packet should be preservedTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ffneighborInfoMultipleNeighborsAllRecordedTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3engine Tff7b72= Te6edf3createEngineTb4b4b4(Tff7b72thisTb4b4b4)

Te6edf3nodeRepositoryTb4b4b4.Te6edf3setMyNodeInfoTb4b4b4(Te6edf3createMyNodeInfoTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3startScanTb4b4b4(Te6edf3testPresetsTb4b4b4, Te6edf3dwellDurationSeconds Tff7b72= T79c0ff6T79c0ff0Tb4b4b4)

Te6edf3awaitDwellTb4b4b4(Te6edf3engineTb4b4b4)

Tff7b72val Te6edf3niPacket Tff7b72= Te6edf3neighborInfoPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff7T79c0ff7T79c0ff7T79c0ff7Tb4b4b4, Te6edf3neighborNodeIds Tff7b72= Te6edf3listOfTb4b4b4(T79c0ff1T79c0ff0T79c0ff1Tb4b4b4, T79c0ff1T79c0ff0T79c0ff2Tb4b4b4, T79c0ff1T79c0ff0T79c0ff3Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3onPacketReceivedTb4b4b4(Te6edf3niPacketTb4b4b4, Te6edf3dataPacketTb4b4b4(Te6edf3from Tff7b72= T79c0ff7T79c0ff7T79c0ff7T79c0ff7Tb4b4b4)Tb4b4b4)

Te6edf3engineTb4b4b4.Te6edf3stopScanTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3nodes Tff7b72= Te6edf3discoveryDaoTb4b4b4.Te6edf3discoveredNodesTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)

T8b949e// Node 7777 (the sender) + 3 mesh neighbors

Tff7b72val Te6edf3meshNodes Tff7b72= Te6edf3nodesTb4b4b4.Te6edf3filter Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3neighborType Tff7b72=Tff7b72= Ta5d6ff"Ta5d6ffmeshTa5d6ff" Tb4b4b4}

Te6edf3assertEqualsTb4b4b4(T79c0ff3Tb4b4b4, Te6edf3meshNodesTb4b4b4.Te6edf3sizeTb4b4b4, Ta5d6ff"Ta5d6ffAll neighbor IDs from NeighborInfo should be recordedTa5d6ff"Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3meshNodesTb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3nodeNum Tb4b4b4}Tb4b4b4.Te6edf3containsAllTb4b4b4(Te6edf3listOfTb4b4b4(T79c0ff1T79c0ff0T79c0ff1LTb4b4b4, T79c0ff1T79c0ff0T79c0ff2LTb4b4b4, T79c0ff1T79c0ff0T79c0ff3LTb4b4b4)Tb4b4b4)Tb4b4b4)

Tb4b4b4}

T8b949e// endregion

T8b949e// region Helpers

Tff7b72private Tff7b72fun Td2a8ffcreateMyNodeInfoTb4b4b4(Te6edf3nodeNumTb4b4b4: Tffa657Int Tff7b72= T79c0ff1T79c0ff0T79c0ff0T79c0ff0Tb4b4b4) Tff7b72= Te6edf3MyNodeInfoTb4b4b4(

Te6edf3myNodeNum Tff7b72= Te6edf3nodeNumTb4b4b4,

Te6edf3hasGPS Tff7b72= Tff7b72trueTb4b4b4,

Te6edf3model Tff7b72= Ta5d6ff"Ta5d6ffTestModelTa5d6ff"Tb4b4b4,

Te6edf3firmwareVersion Tff7b72= Ta5d6ff"Ta5d6ff2.0.0Ta5d6ff"Tb4b4b4,

Te6edf3couldUpdate Tff7b72= Tff7b72falseTb4b4b4,

Te6edf3shouldUpdate Tff7b72= Tff7b72falseTb4b4b4,

Te6edf3currentPacketId Tff7b72= T79c0ff1LTb4b4b4,

Te6edf3messageTimeoutMsec Tff7b72= T79c0ff5T79c0ff0T79c0ff0T79c0ff0Tb4b4b4,

Te6edf3minAppVersion Tff7b72= T79c0ff1Tb4b4b4,

Te6edf3maxChannels Tff7b72= T79c0ff8Tb4b4b4,

Te6edf3hasWifi Tff7b72= Tff7b72falseTb4b4b4,

Te6edf3channelUtilization Tff7b72= T79c0ff0fTb4b4b4,

Te6edf3airUtilTx Tff7b72= T79c0ff0fTb4b4b4,

Te6edf3deviceId Tff7b72= Ta5d6ff"Ta5d6fftest-deviceTa5d6ff"Tb4b4b4,

Tb4b4b4)

Tff7b72private Tff7b72fun Td2a8ffpositionPacketTb4b4b4(Te6edf3fromTb4b4b4: Tffa657IntTb4b4b4, Te6edf3latITb4b4b4: Tffa657IntTb4b4b4, Te6edf3lonITb4b4b4: Tffa657IntTb4b4b4, Te6edf3snrTb4b4b4: Tffa657Float Tff7b72= T79c0ff5.5fTb4b4b4, Te6edf3rssiTb4b4b4: Tffa657Int Tff7b72= Tff7b72-T79c0ff7T79c0ff0Tb4b4b4)Tb4b4b4: Te6edf3MeshPacket Tb4b4b4{

Tff7b72val Te6edf3posPayload Tff7b72= Te6edf3PositionTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3encodeTb4b4b4(Te6edf3PositionTb4b4b4(Te6edf3latitude_i Tff7b72= Te6edf3latITb4b4b4, Te6edf3longitude_i Tff7b72= Te6edf3lonITb4b4b4)Tb4b4b4)Tb4b4b4.Te6edf3toByteStringTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3data Tff7b72= Te6edf3DataTb4b4b4(Te6edf3portnum Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3POSITION_APPTb4b4b4, Te6edf3payload Tff7b72= Te6edf3posPayloadTb4b4b4)

Tff7b72return Te6edf3MeshPacketTb4b4b4(Te6edf3from Tff7b72= Te6edf3fromTb4b4b4, Te6edf3decoded Tff7b72= Te6edf3dataTb4b4b4, Te6edf3rx_snr Tff7b72= Te6edf3snrTb4b4b4, Te6edf3rx_rssi Tff7b72= Te6edf3rssiTb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8fftextMessagePacketTb4b4b4(Te6edf3fromTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3MeshPacket Tb4b4b4{

Tff7b72val Te6edf3data Tff7b72= Te6edf3DataTb4b4b4(Te6edf3portnum Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APPTb4b4b4, Te6edf3payload Tff7b72= Ta5d6ff"Ta5d6ffhelloTa5d6ff"Tb4b4b4.Te6edf3encodeToByteArrayTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3toByteStringTb4b4b4(Tb4b4b4)Tb4b4b4)

Tff7b72return Te6edf3MeshPacketTb4b4b4(Te6edf3from Tff7b72= Te6edf3fromTb4b4b4, Te6edf3decoded Tff7b72= Te6edf3dataTb4b4b4, Te6edf3rx_snr Tff7b72= T79c0ff3.0fTb4b4b4, Te6edf3rx_rssi Tff7b72= Tff7b72-T79c0ff8T79c0ff0Tb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffneighborInfoPacketTb4b4b4(Te6edf3fromTb4b4b4: Tffa657IntTb4b4b4, Te6edf3neighborNodeIdsTb4b4b4: Te6edf3ListTff7b72<Tffa657IntTff7b72>Tb4b4b4)Tb4b4b4: Te6edf3MeshPacket Tb4b4b4{

Tff7b72val Te6edf3neighbors Tff7b72= Te6edf3neighborNodeIdsTb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3NeighborTb4b4b4(Te6edf3node_id Tff7b72= Tffa657itTb4b4b4) Tb4b4b4}

Tff7b72val Te6edf3ni Tff7b72= Te6edf3NeighborInfoTb4b4b4(Te6edf3node_id Tff7b72= Te6edf3fromTb4b4b4, Te6edf3neighbors Tff7b72= Te6edf3neighborsTb4b4b4)

Tff7b72val Te6edf3payload Tff7b72= Te6edf3NeighborInfoTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3encodeTb4b4b4(Te6edf3niTb4b4b4)Tb4b4b4.Te6edf3toByteStringTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3data Tff7b72= Te6edf3DataTb4b4b4(Te6edf3portnum Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3NEIGHBORINFO_APPTb4b4b4, Te6edf3payload Tff7b72= Te6edf3payloadTb4b4b4)

Tff7b72return Te6edf3MeshPacketTb4b4b4(Te6edf3from Tff7b72= Te6edf3fromTb4b4b4, Te6edf3decoded Tff7b72= Te6edf3dataTb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffdataPacketTb4b4b4(Te6edf3fromTb4b4b4: Tffa657IntTb4b4b4) Tff7b72= Te6edf3DataPacketTb4b4b4(

Te6edf3to Tff7b72= Te6edf3NodeAddressTb4b4b4.Te6edf3ID_BROADCASTTb4b4b4,

Te6edf3bytes Tff7b72= Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4,

Te6edf3dataType Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3POSITION_APPTb4b4b4.Te6edf3valueTb4b4b4,

Te6edf3from Tff7b72= Ta5d6ff"Ta5d6ff!Tffd700${Te6edf3fromTb4b4b4.Te6edf3toStringTb4b4b4(T79c0ff1T79c0ff6Tb4b4b4)Tffd700}Ta5d6ff"Tb4b4b4,

Te6edf3hopStart Tff7b72= T79c0ff3Tb4b4b4,

Te6edf3hopLimit Tff7b72= T79c0ff3Tb4b4b4,

Tb4b4b4)

T8b949e// endregion

Tb4b4b4}

T8b949e// region Inline test doubles

Tff7b72private Tff7b72class T56d364PacketTestCollectorRegistry Tb4b4b4: Te6edf3DiscoveryPacketCollectorRegistry Tb4b4b4{

Tff7b72override Tff7b72var Te6edf3collectorTb4b4b4: Te6edf3DiscoveryPacketCollector? Tff7b72= Tff7b72null

Tb4b4b4}

Tff7b72private Tff7b72class T56d364PacketTestAiProvider Tb4b4b4: Te6edf3DiscoverySummaryAiProvider Tb4b4b4{

Tff7b72override Tff7b72val Te6edf3isAvailableTb4b4b4: Tffa657Boolean Tff7b72= Tff7b72false

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgenerateSessionSummaryTb4b4b4(

Te6edf3sessionTb4b4b4: Te6edf3DiscoverySessionEntityTb4b4b4,

Te6edf3presetResultsTb4b4b4: Te6edf3ListTff7b72<Te6edf3DiscoveryPresetResultEntityTff7b72>Tb4b4b4,

Tb4b4b4)Tb4b4b4: Tffa657String? Tff7b72= Tff7b72null

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgeneratePresetSummaryTb4b4b4(Te6edf3resultTb4b4b4: Te6edf3DiscoveryPresetResultEntityTb4b4b4)Tb4b4b4: Tffa657String? Tff7b72= Tff7b72null

Tb4b4b4}

Tff7b72private Tff7b72class T56d364InMemoryDiscoveryDao Tb4b4b4: Te6edf3DiscoveryDao Tb4b4b4{

Tff7b72private Tff7b72var Te6edf3nextSessionId Tff7b72= T79c0ff1L

Tff7b72private Tff7b72var Te6edf3nextPresetResultId Tff7b72= T79c0ff1L

Tff7b72private Tff7b72var Te6edf3nextNodeId Tff7b72= T79c0ff1L

Tff7b72val Te6edf3sessions Tff7b72= Te6edf3mutableMapOfTff7b72<Tffa657LongTb4b4b4, Te6edf3DiscoverySessionEntityTff7b72>Tb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3presetResults Tff7b72= Te6edf3mutableMapOfTff7b72<Tffa657LongTb4b4b4, Te6edf3DiscoveryPresetResultEntityTff7b72>Tb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3discoveredNodes Tff7b72= Te6edf3mutableMapOfTff7b72<Tffa657LongTb4b4b4, Te6edf3DiscoveredNodeEntityTff7b72>Tb4b4b4(Tb4b4b4)

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffinsertSessionTb4b4b4(Te6edf3sessionTb4b4b4: Te6edf3DiscoverySessionEntityTb4b4b4)Tb4b4b4: Tffa657Long Tb4b4b4{

Tff7b72val Te6edf3id Tff7b72= Te6edf3nextSessionIdTff7b72+Tff7b72+

Te6edf3sessionsTff7b72[Te6edf3idTff7b72] Tff7b72= Te6edf3sessionTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3id Tff7b72= Te6edf3idTb4b4b4)

Tff7b72return Te6edf3id

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffupdateSessionTb4b4b4(Te6edf3sessionTb4b4b4: Te6edf3DiscoverySessionEntityTb4b4b4) Tb4b4b4{

Te6edf3sessionsTff7b72[Te6edf3sessionTb4b4b4.Te6edf3idTff7b72] Tff7b72= Te6edf3session

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffgetAllSessionsTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3ListTff7b72<Te6edf3DiscoverySessionEntityTff7b72>Tff7b72> Tff7b72=

Te6edf3flowOfTb4b4b4(Te6edf3sessionsTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3sortedByDescending Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3timestamp Tb4b4b4}Tb4b4b4)

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetAllSessionsSnapshotTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3ListTff7b72<Te6edf3DiscoverySessionEntityTff7b72> Tff7b72= Te6edf3sessionsTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetSessionTb4b4b4(Te6edf3sessionIdTb4b4b4: Tffa657LongTb4b4b4)Tb4b4b4: Te6edf3DiscoverySessionEntity? Tff7b72= Te6edf3sessionsTff7b72[Te6edf3sessionIdTff7b72]

Tff7b72override Tff7b72fun Td2a8ffgetSessionFlowTb4b4b4(Te6edf3sessionIdTb4b4b4: Tffa657LongTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3DiscoverySessionEntity?Tff7b72> Tff7b72= Te6edf3MutableStateFlowTb4b4b4(Te6edf3sessionsTff7b72[Te6edf3sessionIdTff7b72]Tb4b4b4)

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffdeleteSessionTb4b4b4(Te6edf3sessionIdTb4b4b4: Tffa657LongTb4b4b4) Tb4b4b4{

Te6edf3sessionsTb4b4b4.Te6edf3removeTb4b4b4(Te6edf3sessionIdTb4b4b4)

Tff7b72val Te6edf3resultIds Tff7b72= Te6edf3presetResultsTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3filter Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3sessionId Tff7b72=Tff7b72= Te6edf3sessionId Tb4b4b4}Tb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3id Tb4b4b4}

Te6edf3resultIdsTb4b4b4.Te6edf3forEach Tb4b4b4{ Te6edf3rid Tff7b72-Tff7b72>

Te6edf3discoveredNodesTb4b4b4.Te6edf3entriesTb4b4b4.Te6edf3removeAll Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3presetResultId Tff7b72=Tff7b72= Te6edf3rid Tb4b4b4}

Te6edf3presetResultsTb4b4b4.Te6edf3removeTb4b4b4(Te6edf3ridTb4b4b4)

Tb4b4b4}

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffinsertPresetResultTb4b4b4(Te6edf3resultTb4b4b4: Te6edf3DiscoveryPresetResultEntityTb4b4b4)Tb4b4b4: Tffa657Long Tb4b4b4{

Tff7b72val Te6edf3id Tff7b72= Te6edf3nextPresetResultIdTff7b72+Tff7b72+

Te6edf3presetResultsTff7b72[Te6edf3idTff7b72] Tff7b72= Te6edf3resultTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3id Tff7b72= Te6edf3idTb4b4b4)

Tff7b72return Te6edf3id

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffupdatePresetResultTb4b4b4(Te6edf3resultTb4b4b4: Te6edf3DiscoveryPresetResultEntityTb4b4b4) Tb4b4b4{

Te6edf3presetResultsTff7b72[Te6edf3resultTb4b4b4.Te6edf3idTff7b72] Tff7b72= Te6edf3result

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetPresetResultsTb4b4b4(Te6edf3sessionIdTb4b4b4: Tffa657LongTb4b4b4) Tff7b72= Te6edf3presetResultsTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3filter Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3sessionId Tff7b72=Tff7b72= Te6edf3sessionId Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffgetPresetResultsFlowTb4b4b4(Te6edf3sessionIdTb4b4b4: Tffa657LongTb4b4b4) Tff7b72=

Te6edf3flowOfTb4b4b4(Te6edf3presetResultsTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3filter Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3sessionId Tff7b72=Tff7b72= Te6edf3sessionId Tb4b4b4}Tb4b4b4)

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffinsertDiscoveredNodeTb4b4b4(Te6edf3nodeTb4b4b4: Te6edf3DiscoveredNodeEntityTb4b4b4)Tb4b4b4: Tffa657Long Tb4b4b4{

Tff7b72val Te6edf3id Tff7b72= Te6edf3nextNodeIdTff7b72+Tff7b72+

Te6edf3discoveredNodesTff7b72[Te6edf3idTff7b72] Tff7b72= Te6edf3nodeTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3id Tff7b72= Te6edf3idTb4b4b4)

Tff7b72return Te6edf3id

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffinsertDiscoveredNodesTb4b4b4(Te6edf3nodesTb4b4b4: Te6edf3ListTff7b72<Te6edf3DiscoveredNodeEntityTff7b72>Tb4b4b4) Tb4b4b4{

Te6edf3nodesTb4b4b4.Te6edf3forEach Tb4b4b4{ Te6edf3insertDiscoveredNodeTb4b4b4(Tffa657itTb4b4b4) Tb4b4b4}

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffupdateDiscoveredNodeTb4b4b4(Te6edf3nodeTb4b4b4: Te6edf3DiscoveredNodeEntityTb4b4b4) Tb4b4b4{

Te6edf3discoveredNodesTff7b72[Te6edf3nodeTb4b4b4.Te6edf3idTff7b72] Tff7b72= Te6edf3node

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetDiscoveredNodesTb4b4b4(Te6edf3presetResultIdTb4b4b4: Tffa657LongTb4b4b4) Tff7b72=

Te6edf3discoveredNodesTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3filter Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3presetResultId Tff7b72=Tff7b72= Te6edf3presetResultId Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffgetDiscoveredNodesFlowTb4b4b4(Te6edf3presetResultIdTb4b4b4: Tffa657LongTb4b4b4) Tff7b72=

Te6edf3flowOfTb4b4b4(Te6edf3discoveredNodesTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3filter Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3presetResultId Tff7b72=Tff7b72= Te6edf3presetResultId Tb4b4b4}Tb4b4b4)

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetUniqueNodeNumsTb4b4b4(Te6edf3sessionIdTb4b4b4: Tffa657LongTb4b4b4) Tff7b72= Te6edf3presetResultsTb4b4b4.Te6edf3values

Tb4b4b4.Te6edf3filter Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3sessionId Tff7b72=Tff7b72= Te6edf3sessionId Tb4b4b4}

Tb4b4b4.Te6edf3flatMap Tb4b4b4{ Te6edf3pr Tff7b72-Tff7b72> Te6edf3discoveredNodesTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3filter Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3presetResultId Tff7b72=Tff7b72= Te6edf3prTb4b4b4.Te6edf3id Tb4b4b4} Tb4b4b4}

Tb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3nodeNum Tb4b4b4}

Tb4b4b4.Te6edf3distinctTb4b4b4(Tb4b4b4)

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetUniqueNodeCountTb4b4b4(Te6edf3sessionIdTb4b4b4: Tffa657LongTb4b4b4) Tff7b72= Te6edf3getUniqueNodeNumsTb4b4b4(Te6edf3sessionIdTb4b4b4)Tb4b4b4.Te6edf3size

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetMaxDistanceTb4b4b4(Te6edf3sessionIdTb4b4b4: Tffa657LongTb4b4b4) Tff7b72= Te6edf3presetResultsTb4b4b4.Te6edf3values

Tb4b4b4.Te6edf3filter Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3sessionId Tff7b72=Tff7b72= Te6edf3sessionId Tb4b4b4}

Tb4b4b4.Te6edf3flatMap Tb4b4b4{ Te6edf3pr Tff7b72-Tff7b72> Te6edf3discoveredNodesTb4b4b4.Te6edf3valuesTb4b4b4.Te6edf3filter Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3presetResultId Tff7b72=Tff7b72= Te6edf3prTb4b4b4.Te6edf3id Tb4b4b4} Tb4b4b4}

Tb4b4b4.Te6edf3mapNotNull Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3distanceFromUser Tb4b4b4}

Tb4b4b4.Te6edf3maxOrNullTb4b4b4(Tb4b4b4)

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetSessionWithResultsTb4b4b4(Te6edf3sessionIdTb4b4b4: Tffa657LongTb4b4b4) Tff7b72= Te6edf3sessionsTff7b72[Te6edf3sessionIdTff7b72]

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffmarkInterruptedSessionsTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3sessionsTb4b4b4.Te6edf3keysTb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3forEach Tb4b4b4{ Te6edf3key Tff7b72-Tff7b72>

Tff7b72val Te6edf3session Tff7b72= Te6edf3sessionsTff7b72[Te6edf3keyTff7b72]Tff7b72!!

Tff7b72if Tb4b4b4(Te6edf3sessionTb4b4b4.Te6edf3completionStatus Tff7b72=Tff7b72= Ta5d6ff"Ta5d6ffin_progressTa5d6ff"Tb4b4b4) Tb4b4b4{

Te6edf3sessionsTff7b72[Te6edf3keyTff7b72] Tff7b72= Te6edf3sessionTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3completionStatus Tff7b72= Ta5d6ff"Ta5d6ffinterruptedTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tb4b4b4}

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetInterruptedSessionTb4b4b4(Te6edf3deviceAddressTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Te6edf3DiscoverySessionEntity? Tff7b72= Te6edf3sessionsTb4b4b4.Te6edf3values

Tb4b4b4.Te6edf3filter Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3deviceAddress Tff7b72=Tff7b72= Te6edf3deviceAddress Tff7b72&Tff7b72& Tffa657itTb4b4b4.Te6edf3completionStatus Tff7b72in Te6edf3setOfTb4b4b4(Ta5d6ff"Ta5d6ffin_progressTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffinterruptedTa5d6ff"Tb4b4b4) Tb4b4b4}

Tb4b4b4.Te6edf3maxByOrNull Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3timestamp Tb4b4b4}

Tb4b4b4}